package cn.zs.supply.common.core.mq;

import lombok.extern.slf4j.Slf4j;
@Slf4j
public class ShutDownWork extends Thread {
    @Override
    public void run() {
        try {
            RocketProducer.closeProducer();
            log.info("关闭RocketProducer");
        } catch (Exception ex) {
            log.error("关闭RocketProducer异常",ex);
        }
    }
}